package at.ac.univie.bi.transformation.service.input;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.sql.Timestamp;
import java.util.ArrayList;
import java.util.List;

import at.ac.univie.bi.transformation.model.input.KrankenhausaufenthaltLeistung;
import at.ac.univie.bi.transformation.model.input.Medication;
import at.ac.univie.bi.transformation.persistence.DBHandler;

public class KHALeistungService extends AbstractInputEntityService {
	
	public static List<KrankenhausaufenthaltLeistung> selectKHALeistungenByKHAId(int khaId)
	  {
		  String tableName = "KrankenhausaufenthaltLeistung";
		  List<KrankenhausaufenthaltLeistung> khaLeistungen = new ArrayList<KrankenhausaufenthaltLeistung>();
		  Statement stmt = null;
		  Connection oldDB = DBHandler.getOldDB();
		  
	      try
	      {
	          stmt = oldDB.createStatement();
	          ResultSet results = stmt.executeQuery("select * from " + tableName +" WHERE krankenhausaufenthaltId="+ khaId);
	          

	          while(results.next())
	          {
	              int leistungId = results.getInt("leistungId");
	              int krankenhausaufenthaltId = results.getInt("krankenhausaufenthaltId");
	              
	              KrankenhausaufenthaltLeistung khaLeistung = new KrankenhausaufenthaltLeistung();
	              khaLeistung.setLeistungId(leistungId);
	              khaLeistung.setKhaId(krankenhausaufenthaltId);
	              
	              khaLeistungen.add(khaLeistung);
	              
	          }
	          results.close();
	          stmt.close();

	      }
	      catch (SQLException sqlExcept)
	      {
	          sqlExcept.printStackTrace();
	      }
	      
	      
	      return khaLeistungen;
	  }
	
	public static List<KrankenhausaufenthaltLeistung> selectKHALeistungen()
	  {
		  String tableName = "KrankenhausaufenthaltLeistung";
		  List<KrankenhausaufenthaltLeistung> khaLeistungen = new ArrayList<KrankenhausaufenthaltLeistung>();
		  Statement stmt = null;
		  Connection oldDB = DBHandler.getOldDB();
		  
	      try
	      {
	          stmt = oldDB.createStatement();
	          ResultSet results = stmt.executeQuery("select * from " + tableName);
	          

	          while(results.next())
	          {
	              int leistungId = results.getInt("leistungId");
	              int krankenhausaufenthaltId = results.getInt("krankenhausaufenthaltId");
	              
	              KrankenhausaufenthaltLeistung khaLeistung = new KrankenhausaufenthaltLeistung();
	              khaLeistung.setLeistungId(leistungId);
	              khaLeistung.setKhaId(krankenhausaufenthaltId);
	              
	              khaLeistungen.add(khaLeistung);
	              
	          }
	          results.close();
	          stmt.close();

	      }
	      catch (SQLException sqlExcept)
	      {
	          sqlExcept.printStackTrace();
	      }
	      
	      
	      return khaLeistungen;
	  }

	
	@Override
	public void readAll() {
		// TODO Auto-generated method stub
		
	}
	
	

}
